package com.ververica.cdc.guass.source.kafka.table;


import org.apache.flink.table.types.DataType;

import java.io.Serializable;

public class PhysicalColumn implements Serializable {
    private String name;
    private DataType dataType;

    public PhysicalColumn(String name, DataType dataType) {
        this.name = name;
        this.dataType = dataType;
    }

    public String getName() {
        return name;
    }

    public DataType getDataType() {
        return dataType;
    }
}